
package kvsnode;

import java.util.concurrent.ExecutorService;

/**
 * A thread to process messages in multiple channels.
 * It passes messages from each channel to the converging one channel to simulate one thread
 * in each node.
 * 
 * @version 5/8/2013
 */
public class MessageProcessorForEachChannel implements Runnable
{
  
  /**
   * The converging queue for the node. 
   */
  private final ExecutorService my_converging_queue;

  /**
   * Constructor.
   * 
   * @param the_converging_queue a queue to gather all the messages from multiple channels.
   */
  public MessageProcessorForEachChannel(final ExecutorService the_converging_queue)
  {
    my_converging_queue = the_converging_queue;
  }
  
  /**
   * {@inheritDoc}
   */
  @Override
  public void run()
  {
    // to do
  }

}
